package com.flute.icrawler.app.distributed;

import com.flute.haflute.jobbox.base.StatusReporter;
import com.flute.haflute.jobbox.base.StatusReporter.JOB_STATUS;
import com.flute.icrawler.framework.framework.AbstractCrawlEndedListener;
import com.flute.icrawler.framework.framework.ICrawlListener;

public class DistributedCrawlJobListener extends AbstractCrawlEndedListener implements ICrawlListener {
	private StatusReporter reporter = null;
	
	public DistributedCrawlJobListener(StatusReporter reporter) {
		this.reporter = reporter;
	}
	/* 
	 * @see com.cpkf.yyjd.crawler.framework.AbstractCrawlListener#dealNotification()
	 */
	@Override
	public void dealNotification() {
		reporter.setStatus(JOB_STATUS.FINISHED, "message from " + getClass().getSimpleName());
		
	}

}
